package cn.lesaas.esb.poc.route;

import java.util.Map;

import org.apache.camel.Exchange;
import org.apache.camel.Processor;

public class JobProcess implements Processor {
	public void process(Exchange exchange) throws Exception {
		Map<String, String> map = exchange.getIn().getBody(Map.class);
		exchange.getIn().setBody(map.get("message"));
	}
}
